package ocg.common.re.feed;


import ocg.common.re.jdbc.JdbcQuery;

import java.sql.Connection;

/**
 * Created by chenbo on 2018/3/7.
 */
public class Feeder {

    public Feeder() {
    }

    /**
     * 通过查询数据库 ， 获取数据集 List<Map<String,Object>>
     * @param Url               数据库地址
     * @param user              数据库用户名
     * @param password          数据库密码
     * @param sql               sql 查询语句
     * @return
     */
    public static Feed jdbcFeed( String Url , String user , String password , String sql){
        return new Feed ( new JdbcQuery ( Url , user , password ).query ( sql ) );
    }

    /**
     * 通过查询数据库 ， 获取数据集 List<Map<String,Object>>
     * @param connection            数据库对象 connection
     * @param sql                   sql 查询语句
     * @return
     */
    public static Feed jdbcFeed( Connection connection , String sql){
        return new Feed ( new JdbcQuery ( connection ).query ( sql ) );
    }

    /**
     * 获取 csv 中的数据集 List<Map<String,Object>>
     * @param path
     * @return
     */
    public static Feed csvFeed(String path ){
        return null;
    }

    /**
     * 获取 json 中的数据集 List<Map<String,Object>>
     * @param path
     * @return
     */
    public static Feed jsonFeed(String path ){
        return null;
    }

}

